// 操作order_information表的路由
const express = require('express')
// 引入连接池模块
const pool = require('../pool')
// 引入路由器
const router = express.Router()

// req请求的数据，res响应的数据
router.post('/',(req, res, next) => {
    const obj = req.body
    pool.query('insert into order_information set ?', [obj], (err,r) => {
        // 如果有错误放回给错误处理中间件
        if (err) {
            return next(err)
        }
        // 返回的数据
        res.send({status:200,msg:'添加成功',data: r})
    })
})

// 修改订单状态
router.post('/updataOrder',(req, res, next) => {
    const obj = req.body
    pool.query('UPDATE order_information SET pay = 1 WHERE ?', [obj], (err,r) => {
        // 如果有错误放回给错误处理中间件
        if (err) {
            return next(err)
        }
        // 返回的数据
        res.send({status:200,msg:'修改成功',data: r})
    })
})

// 查询用户订单
router.get('/getOrder',(req, res, next) => {
    const obj = req.query
    pool.query('select * from order_information where ?', [obj], (err,r) => {
        if (err) {
            return next(err)
        }
        res.send({status:200,msg:'查询成功',data: r})
    })
})

// 查询用户订单
router.get('/deleteOrder',(req, res, next) => {
    const obj = req.query
    pool.query('DELETE FROM order_information WHERE ?', [obj], (err,r) => {
        if (err) {
            return next(err)
        }
        res.send({status:200,msg:'删除成功',data: r})
    })
})

// 暴露路由器
module.exports = router